package com.wenheng.hodel;

import lombok.extern.slf4j.Slf4j;

@Slf4j
public class DynamicDataSourceHolder {
    /**
     * 本地线程共享对象
     */
    private static final ThreadLocal<String> THREAD_LOAD = new ThreadLocal<String>();
    //将线程中的信息写入当前数据变量中
    public static void putDataSource(String name){
        log.info("切换到 {"+name+"} 数据库");
        THREAD_LOAD.set(name);
    }
    //获得当前线程中的信息
    public static String getDataSource(){
        return THREAD_LOAD.get();
    }
    //主动删除线程中的信息
    public static void removeDataSource(){
        THREAD_LOAD.remove();
    }

}
